package org.study.event.test.consumer.impl;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.study.event.test.consumer.ConsumerMessage;
import org.study.event.test.vo.Message;

import com.google.common.eventbus.Subscribe;

public class ConsumerMessageImpl implements ConsumerMessage {

	private Logger logger = LoggerFactory.getLogger(ConsumerMessageImpl.class);
    
	@Subscribe
	@Override
	public void consumerMessage(Message message) {
		logger.info("=====接受消息====");
		logger.info("消息内容:" + message.getContext());
		logger.info("消息时间:" + message.getTime());
		logger.info("================");
	}

}
